package org.apache.spark

object BasicApp2 {
    def main(args: Array[String]): Unit = {
        val conf: SparkConf = new SparkConf().setMaster("local").setAppName("2")
        val sc = new SparkContext(conf)

        sc.parallelize(List(1,2,3,4,5)).filter(_>1).foreach(println)

        sc.stop()
    }
}
